package cn.tedu.pdfamily.product.service.impl;

import cn.tedu.pdfamily.product.exception.ServiceException;
import cn.tedu.pdfamily.product.mapper.ReplyMapper;
import cn.tedu.pdfamily.product.pojo.dto.ReplyAddNewDTO;
import cn.tedu.pdfamily.product.pojo.dto.ReplyUpdateDTO;
import cn.tedu.pdfamily.product.pojo.entity.Reply;
import cn.tedu.pdfamily.product.pojo.vo.ReplyListItemVO;
import cn.tedu.pdfamily.product.pojo.vo.ReplyStandardVO;
import cn.tedu.pdfamily.product.service.IReplyService;
import cn.tedu.pdfamily.product.web.ServiceCode;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 处理评论数据的业务实现类, 此处实现文件夹外对应的接口中的方法
 *
 * @author Half_Summer
 * @version 0.0.1
 */
@Slf4j
@Service
public class ReplytServiceImpl implements IReplyService {
    //注入ReplyMapper接口
    @Autowired
    private ReplyMapper replyMapper;

    public ReplytServiceImpl() {
        log.debug("创建业务对象：ReplytServiceImpl");
    }

    //[方法] 新增评论
    @Override
    public void addNew(ReplyAddNewDTO replyAddNewDTO){
        log.debug("准备新增评论, 参数:{}",replyAddNewDTO);
        //从参数中获取用户id和所评价的商品id,以查询用户是否已经评论过该商品
       String replyUseNickname=replyAddNewDTO.getUserNickname();
        Long commentId=replyAddNewDTO.getCommentId();
        //打点输出检查是否成功获取对应信息
        log.debug("检查用户{}是否已经评论过商品(id={})");
        //检查是否存在查询结果
        Integer count=replyMapper.countByUserNicknameAndCommentId(replyUseNickname,commentId);
        if(count>0){
            //存在查询结果, 用户已经评论过了
            String message="添加分类失败，分类名称已经被占用！";
            log.debug(message);
            //抛出异常50000
            throw new ServiceException(ServiceCode.ERR_INSERT,message);
        }
        //用户没有评论过商品, 准备新增评论
        log.debug("分类名称没有被占用，将向分类表中插入数据");
        //新建评论对象
        Reply reply = new Reply();
        //将传来的对象中的参数复制到新建对象中
        BeanUtils.copyProperties(replyAddNewDTO,reply);
        //将复制完属性的reply对象添加到数据库
        log.debug("准备将新增评论{}添加到数据库...",reply);
        //判断是否成功添加
        int rows=replyMapper.insert(reply);
        if(rows!=1){
            //数据没有成功添加
            String message="未知异常(1): 新增评论失败, 请稍后重试.";
            log.debug(message);
            //抛出异常50000
            throw new ServiceException(ServiceCode.ERR_INSERT,message);
        }
        log.debug("新增评论完成.");
        //没有异常将会在Controller中返回JsonResult.ok
    }
    @Override
    public void delete(Long id) {
        log.debug("开始处理【根据id删除分类】的业务，参数：{}", id);
        // 调用Mapper对象的getStandardById()执行查询
        ReplyStandardVO queryResult = replyMapper.getStandardById(id);
        // 判断查询结果是否为null
        if (queryResult == null) {
            // 是：无此id对应的数据，将不允许执行删除操作，则抛出异常
            String message = "删除分类失败，尝试访问的数据不存在！";
            log.debug(message);
            throw new ServiceException(ServiceCode.ERR_NOT_FOUND, message);
        }
        //TODO 删除分类,与商品表有关联,需做规则完善
        log.debug("即将执行删除，参数：{}", id);
        int rows = replyMapper.deleteById(id);
        if (rows != 1) {
            String message = "删除分类失败，服务器忙，请稍后再尝试！";
            log.debug(message);
            throw new ServiceException(ServiceCode.ERR_DELETE, message);
        }
    }

    @Override
    public void updateInfoById(Long id, ReplyUpdateDTO replyUpdateDTO) {
        log.debug("开始处理【修改分类详情】的业务，参数ID：{}, 新数据：{}", id, replyUpdateDTO);
        // 规则:修改的名称不能为已存在的名称
        {
            int count = replyMapper.countByUserNicknameAndCommentId(replyUpdateDTO.getUserNickname(), replyUpdateDTO.getCommentId());
            if (count > 0) {
                String message = "修改分类详情失败，分类名称已经被占用！";
                log.warn(message);
                throw new ServiceException(ServiceCode.ERR_CONFLICT, message);
            }
        }

        // 调用Mapper对象的getStandardById()方法执行查询
        ReplyStandardVO queryResult = replyMapper.getStandardById(id);
        // 判断查询结果是否为null
        if (queryResult == null) {
            // 是：此id对应的数据不存在，则抛出异常(ERR_NOT_FOUND)
            String message = "修改分类详情失败，尝试访问的数据不存在！";
            log.warn(message);
            throw new ServiceException(ServiceCode.ERR_NOT_FOUND, message);
        }

        Reply reply = new Reply();
        BeanUtils.copyProperties(replyUpdateDTO, reply);
        reply.setId(id);

        // 修改数据
        log.debug("即将修改数据：{}", reply);
        int rows = replyMapper.update(reply);
        if (rows != 1) {
            String message = "修改分类详情失败，服务器忙，请稍后再次尝试！";
            log.warn(message);
            throw new ServiceException(ServiceCode.ERR_UPDATE, message);
        }

    }

    @Override
    public ReplyStandardVO getStandardById(Long id) {
        log.debug("开始处理【根据id查询分类详情】的业务，参数：{}", id);
        ReplyStandardVO reply = replyMapper.getStandardById(id);
        if (reply == null) {
            String message = "获取分类详情失败，尝试访问的数据不存在！";
            log.warn(message);
            throw new ServiceException(ServiceCode.ERR_NOT_FOUND, message);
        }
        return reply;
    }

    @Override
    public List<ReplyListItemVO> list() {
        log.debug("开始处理【查询分类列表】的业务，无参数");
        return replyMapper.list();
    }

    @Override
    public void addNewReply(ReplyAddNewDTO replyAddNewDTO) {

    }

}
